package com.credithc.eagleeye.demo.service.impl;
import com.alibaba.fastjson.JSON;
import com.credithc.eagleeye.demo.vo.UserVo;
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import static com.credithc.eagleeye.demo.config.RabbitMqConfig.TOPIC_EXCHANGE;
import static com.credithc.eagleeye.demo.config.RabbitMqConfig.TOPIC_QUEUE1_ROUTE_KEY;
/**
 * 描 述: <br/>
 * 作 者: zhangjin<br/>
 * 创 建：2019年10月23日<br/>
 * 版 本：v1.0.0<br>
 * <p>
 * 历 史: (版本) 作者 时间 注释 <br/>
 */
@Service
public class RabbitMqServiceImpl {
    @Autowired
    private AmqpTemplate rabbitTemplate;



    // 第一个参数：TopicExchange名字
    // 第二个参数：Route-Key
    // 第三个参数：要发送的内容
    public void send(UserVo user) {
        this.rabbitTemplate.convertAndSend(TOPIC_EXCHANGE,TOPIC_QUEUE1_ROUTE_KEY, JSON.toJSONString(user));
    }
}
